package com.room.search.job.processor;

import com.room.search.repository.RoomGoodsRepository;
import org.springframework.stereotype.Component;
import tech.powerjob.worker.core.processor.ProcessResult;
import tech.powerjob.worker.core.processor.TaskContext;
import tech.powerjob.worker.core.processor.sdk.BasicProcessor;

/**
 * By   : ghd.bright
 * Time : 2022/5/5
 * Description: 定时删除房源类似的数据
 */

@Component
public class DeleteDistinctRoomDataProcessor implements BasicProcessor {

    private final RoomGoodsRepository roomGoodsRepository;

    public DeleteDistinctRoomDataProcessor(RoomGoodsRepository roomGoodsRepository) {
        this.roomGoodsRepository = roomGoodsRepository;
    }


    @Override
    public ProcessResult process(TaskContext context) throws Exception {

        ProcessResult processResult = new ProcessResult();
        processResult.setSuccess(true);
        return processResult;
    }
}
